const WebSocket = require('ws')

const WebSocketServer = WebSocket.Server;

//在3000端口上打开了一个WebSocket Server，该实例由变量wss引用。


//如果有WebSocket请求接入，wss对象可以响应connection事件来处理这个WebSocket：
module.exports=Server={
    init(ebus){
        const wss =new WebSocketServer({
            port:3000
        })
        wss.on('connection',function(ws){  //在connection事件中，回调函数会传入一个WebSocket的实例，表示这个WebSocket连接。
            console.log(`[SERVER 3000] connection()`);
        })
        ebus.on('cmd',(data) => {
            wss.clients.forEach(clinet=>{
                clinet.send(JSON.stringify(data.message))
            })
    
        })
    }
}